//package com.xinzhi.savingpot.userinfo.websocket.service;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component;
//
//import javax.websocket.OnClose;
//import javax.websocket.OnMessage;
//import javax.websocket.OnOpen;
//import javax.websocket.Session;
//import javax.websocket.server.ServerEndpoint;
//import java.util.concurrent.CopyOnWriteArraySet;
//
//@Component
//@ServerEndpoint("/Websocket")
//@Slf4j
//public class Websocket {
//    //用于存放每个websocet客户端对应的信息
//    private static CopyOnWriteArraySet<Websocket> websockets = new CopyOnWriteArraySet<Websocket>();
//    //创建会话对象通过他给客户端发送数据
//    private Session session;
//   @OnOpen
//    public void Onopen(Session session){
//       this.session=session;
//       websockets.add(this);
//       log.info("[Websocket消息]有新的连接,总数:{}",websockets.size());
//   }
//   @OnClose
//    public void onClose(String message){
//       websockets.remove(this);
//       log.info("[Websocket消息]连接断开,总数:{}",websockets.size());
//   }
//
//   @OnMessage
//    public void onMessage(String message){
//       log.info("[Websocket收到客户端发来的消息]");
//   }
//    public void sendMessage(String message){
//
//    }
//
//
//
//}
